package com.love.cloud.common.redis.queue.annotation;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * @author hongdongqu
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface QueueConsumer {
    /**
     * 消息流主题名称
     * @return
     */
    String topic();
    /**
     * 消费者组名称
     */
    String groupName();

    /**
     * 消费者名称
     */
    String name();

    /**
     * 消费ack机制
     * @return
     */
    int consumerAck() default 1;
}
